package com.sali.pojo;

import com.sali.common.UUIDUtil;
import lombok.*;


@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Getter
@Setter
public class KafkaEntity {

    private String brokerIp;

    private String kafkaTopic;

    private String avroFilePath;

    private String consumeOffset = "earliest";

    private String groupId = UUIDUtil.getUUID();
}
